package com.wms.consumer.controller;

import lombok.extern.slf4j.Slf4j;
import org.apache.rocketmq.spring.annotation.RocketMQMessageListener;
import org.apache.rocketmq.spring.core.RocketMQListener;
import org.springframework.stereotype.Component;

/**
 * Description: TODO 消费者接收消息 - 基本消息
 *
 * @version 1.0
 * @author: wangqiang
 * @date: 2023/3/12 23:41
 */
@Component
@Slf4j
// 消费者监听器通过selectorExpression ="tagName"获取指定的TAG消息 ,需要获取多个tag时，使用||分隔："a||b||c"
@RocketMQMessageListener(topic = "base_topic",consumerGroup = "base_group")
public class BaseConsumer implements RocketMQListener<String> {

    @Override
    public void onMessage(String s) {
        log.info("消费者接收-基本信息...{}",s);
    }
}
